package awk.disruptor;

import com.lmax.disruptor.EventHandler;

/**
 * @description:
 * @author: wanghaifeng
 * @date: 2020/12/23
 *
 * 消费者，在此类实现具体的业务逻辑
 */
public class MessageEventListener implements EventHandler<MessageEvent> {
    @Override
    public void onEvent(MessageEvent event, long sequence, boolean endOfBatch) {
        System.out.println("消费者消费消息：" + event.getMessage());
    }
}